package cn.com.utt.unms.job;

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import cn.com.utt.unms.mapper.SmsMarketMapper;
import cn.com.utt.unms.mapper.SmsRecordMapper;
import cn.com.utt.unms.pojo.SmsMarketing;
import cn.com.utt.unms.pojo.SmsRecord;

//@Component("smsUpdateJob")
public class SmsUpdateJob {
	
//	@Autowired
//	private SmsMarketMapper smsMarketMapper;
//	@Autowired
//	private SmsRecordMapper smsRecordMapper;
//	
//	public void doJob() {
//		// 查询状态为发送中的营销策略
//		List<SmsMarketing> list = smsMarketMapper.querySmsMarketByStatus((byte) 3);
//		if (list != null) {
//			for (SmsMarketing smsMarketing : list) {
//				//查询对应smsrecord如果短信发送完成将状态更新为已成功
//				//如果全部失败则将状态更新为发送失败
//				List<SmsRecord> records = smsRecordMapper.querySmsRecordByMarketingId(smsMarketing.getId());
//				//24小时这前的时间
//				//如果有记录超过24小时 还没有发送完成则将状态更改为发送失败
//				long expire = System.currentTimeMillis()-24*60*60*1000;
//				int fail=0,success=0;
//				for (SmsRecord smsRecord : records) {
//					if(smsRecord.getStatus()==2){
//						success++;
//					}else if(smsRecord.getStatus()==3){
//						fail++;
//					}else{
//						//发送中
//						if(smsRecord.getSendTime().getTime()>=expire){
//							smsRecord.setStatus((byte) 3);
//							smsRecordMapper.updateRecord(smsRecord);
//							fail++;
//						}
//					}		
//				}
//				if(success==smsMarketing.getNum()){
//					//发送成功
//					smsMarketing.setStatus((byte)4);
//					smsMarketMapper.updateSmsMarketing(smsMarketing);
//				}else if(fail==smsMarketing.getNum() ) {
//					//发送失败
//					smsMarketing.setStatus((byte)5);
//					smsMarketMapper.updateSmsMarketing(smsMarketing);
//				}else if((success+fail) == smsMarketing.getNum()){
//					//发送完成，有失败有成功
//					smsMarketing.setStatus((byte)4);
//					smsMarketMapper.updateSmsMarketing(smsMarketing);
//				}
//				
//			}
//		}
//	}

}
